package org.dftproject.genesis.core.data.flow;

public interface ICollectorListener<T> {
	
	public void elementAdded(Collector<T> collector, T element);

	public void providerStatusChanged(Collector<T> collector, String providerName, boolean active);

}
